package main

import (
	"fmt"
	"math/rand"
	"time"
)

func generator() chan int {
	out := make(chan int)
	go func() {
		i := 0
		for {
			time.Sleep(
				time.Duration(rand.Intn(1500)) *
					time.Millisecond)
			out <- i
			i++
		}
	}()
	return out
}

func worker(id int, c chan int) {
	for n := range c {
		time.Sleep(time.Second)
		fmt.Printf("Worker %d received %d\n",
			id, n)
	}
}

func createWorker(id int) chan<- int {
	c := make(chan int)
	go worker(id, c)
	return c
}

func main() {
	var c1, c2 = generator(), generator()
	var worker = createWorker(0)

	var values []int
	tm := time.After(10 * time.Second) //十秒后往channel送一个时间
	tick := time.Tick(time.Second)     //定时往channel送一个时间
	for {
		var activeWorker chan<- int //nil,发收数据在select是阻塞的(原子性)，接收不了数据
		var activeValue int
		if len(values) > 0 {
			activeWorker = worker
			activeValue = values[0]
		}

		//使用select进行channel调度，谁来的快收一个channel数据，同时会随机选择一个
		//channel必须同时要发/接数据，不然协程等待阻塞时间长死锁
		select { //非阻塞：从channel中非阻塞获取数据（都没有数据时） + default（超时/退出机制）
		case n := <-c1: //case中必须只能判断信道
			values = append(values, n) //生产数据和消费数据速度不一样，n会被覆盖，所以缓存起来
		case n := <-c2:
			values = append(values, n)
		case activeWorker <- activeValue: //在数据没有准备好的时候，把channel置成nil(select会忽略该分支)，这样select时防止接收脏数据（activeValue=0）
			values = values[1:]

		case <-time.After(800 * time.Millisecond): //select时间（生成数据两次n的时间差）超过800ms，超时
			fmt.Println("timeout")
		case <-tick: //定时查看values累计的长度
			fmt.Println(
				"queue len =", len(values))
		case <-tm: //十秒后程序退出
			fmt.Println("bye")
			return
		}
	}
}
